package com.cloud.service;

import com.alibaba.otter.canal.client.CanalConnector;
import com.alibaba.otter.canal.protocol.Message;

public interface CanalDataHandlerService {
    void handleMessage(Message message, CanalConnector connector);
}
